package cn.tedu.csmall.stock.webapi.consume;

import cn.tedu.csmall.stock.webapi.config.RabbitConfig;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component
//从队列中获取消息，需要监听队列
@RabbitListener(queues = RabbitConfig.STOCK_QUEUE)
public class RabbitConsumer {

    //数据具体处理的过程还是通过方法来实现
    //只能有一个方法上有该注解
    //可以从队列中获取数据，转成指定的格式进行处理
    //队列中是byte[],我们需要LocalDateTime
    //在方法参数中指定即可
    @RabbitHandler
    public void process(LocalDateTime localDateTime){
        System.out.println("接收到消息:"+localDateTime);
    }
}
